package org.huangrui.spark.scala.core.rdd.operate

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @Author hr
 * @Create 2024-10-16 15:58 
 */
object Spark01_Operate {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setMaster("local[*]").setAppName("spark")
    val sc = new SparkContext(conf)

    // TODO RDD的方法
    sc.parallelize(List(1, 2, 3)).foreach(println)
    // RDD的方法会有很多，主要讲解核心，重要的方法
    // 学习的重点：
    //    1. 名字
    //    2. IN
    //    3. OUT
    // RDD的方法会有很多，但是分为2类
    // 1. 转换：将数据向后流转
    // 2. 行动：打开数据开关
    // RDD方法处理数据的分类
    // 1. 单值 : 1, "abc", new User(), new ArrayList(), (Key, Value)
    // 2. 键值 : KV => (Key, Value)
    //          word -> count
    println(("hello", "world"))

    sc.stop()
  }
}
